package cn.xinfei.xdecision.data.core.frame.executors;


import cn.xinfei.xdecision.common.model.datax.enums.CollectStageEnum;

import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.CountDownLatch;

public interface IExecutorService<T> {
   T run(Set<String> varCodes,
         Map<String, Object> inputParam,
         Long datasourceId,
         CollectStageEnum collectStageEnum,
         String requestId);
}
